package com.ehotting.mqbd.zw.netty.service;

import com.ehotting.eaf.core.utils.AssertUtils;
import com.ehotting.mqbd.api.bean.MQDataAble;
import com.ehotting.mqbd.api.bean.MsgStateBean;
import com.ehotting.mqbd.api.enums.MsgStateEnum;
import com.ehotting.mqbd.core.manager.AgentLinkManager;
import com.ehotting.mqbd.core.manager.MqQueueManager;
import com.ehotting.mqbd.core.manager.MsgStateHandlerAble;
import com.ehotting.mqbd.core.manager.MsgStateManager;
import com.ehotting.mqbd.zw.api.bean.ZwMQTcpData;
import com.ehotting.mqbd.zw.api.constants.ActionConstants;
import com.ehotting.mqbd.zw.netty.call.MQZwNettyCaller;
import org.jvnet.hk2.annotations.Service;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ZwMsgStateHandler implements MsgStateHandlerAble {

    public static Logger logger = LoggerFactory.getLogger(ZwMsgStateHandler.class);

    @Autowired
    protected MsgStateManager msgStateManager;
    @Autowired
    protected MqQueueManager mqQueueManager;
    @Autowired
    protected AgentLinkManager agentLinkManager;

    @Override
    public void handleCancel(MQDataAble data) {

    }

    @Override
    public void handleDelete(String agentId) {
        msgStateManager.deleteByAgentIdAndSolving(agentId);
    }


}
